//package com.amigo.online.provider.search.exception;
//
//import java.io.IOException;
//import java.util.ArrayList;
//import java.util.List;
//import java.util.UUID;
//import java.util.concurrent.ArrayBlockingQueue;
//
//import javax.annotation.Resource;
//
//import org.apache.solr.client.solrj.SolrClient;
//import org.apache.solr.client.solrj.SolrServerException;
//import org.apache.solr.common.SolrInputDocument;
//import org.springframework.scheduling.annotation.Async;
//import org.springframework.stereotype.Component;
//
//@Component
//public class Consumer  {
//	public static  ArrayBlockingQueue<String> queue1;
//	@Resource(name="SolrClient_hotword") 
//	private SolrClient solrClient_hotword;
//	@Async("asyncServiceExecutor")
//	public void insertHotWord() {
//		 try {
//         	queue1=SearchServiceImpl.queue;
//         	String q=queue1.take();
//             //往热词索引库添加业务
//         	//为文档添加域
// 			List<SolrInputDocument> doc=new ArrayList<SolrInputDocument>();
// 			// 4、为文档添加域
// 			SolrInputDocument document = new SolrInputDocument();
// 			document.addField("id",UUID.randomUUID()+"");//热词ID
// 			document.addField("hotword", q+"");//热词
// 			doc.add(document);
// 			solrClient_hotword.add(doc);
// 			// 5、向索引库中添加文档。
// 			solrClient_hotword.commit();
//             Thread.sleep(1000);
//         } catch (InterruptedException | SolrServerException | IOException e) {
//             e.printStackTrace();
//         }
//
//	}
//}
